package com.liuyu.common.framework.rocketmq.properties;

import lombok.Data;

import java.util.List;

/**
 * 消费者组
 * @author: liuyu
 * @date: 2022/6/11 21:08
 * @version: 1
 */
@Data
public class ConsumerGroup {
    /**
     * 消费组名称
     */
    private String groupName;
    /**
     *mq的nameserver地址
     */
    private String namesrvAddr;
    /**
     *  #消费者线程数据量
     */
    private Integer consumeThreadMin;
    private Integer consumeThreadMax;
    /**
     *设置一次消费的条数，默认1
     */
    private Integer consumeMessageBatchMaxSize;
    /**
     *是否顺序消费
     */
    private Boolean orderly;
    /**
     *消费模式
     */
    private String messageModel;

    /**
     * 订阅清单
     */
    private List<TopicSubscribe> subscribes;

    /**
     * 处理这个分组的监听器bean名称
     */
    private String listenerBeanName;
}
